

-- source
create table ods_zp_n_star_app_log (
    content string comment '使用$$分割的字符串'
)
with(
'connector' = 'kafka',
'topic' = 'hdp_lbg_supin_star_app_log',
'properties.bootstrap.servers' = '10.178.10.8:9092,10.178.10.10:9092,10.178.10.11:9092,10.178.10.12:9092,10.178.10.13:9092',
'properties.group.id' = 'hdp_lbg_supin-hdp_lbg_supin_star_app_log-BQxsW-www',
'scan.startup.mode' = 'group-offsets',
'properties.client.id' = 'hdp_lbg_supin-hdp_lbg_supin_star_app_log-BQxsW',
'format' = 'raw'
);


